package com.zuoshengli.api;

import org.apache.kafka.clients.consumer.ConsumerRecord;

/**
 * @Description TODO
 * @Author zuoshengli
 **/
public interface KafkaService {
    /**
     * 消费消息
     * @param record
     */
    void processMessage(ConsumerRecord<String, String> record) throws Exception;

    /**
     * 发送kafka消息
     * @param topic
     * @param data
     */
    void sendMessage(String topic, String data);
}
